16e6ed9ebcf3568121ca95d569bbd11ae8963e60,src/main/java/com/deutscheboerse/risk/dave/MongoDBPersistenceVerticle.java,MongoDBPersistenceVerticle,startStoreHandlers,#Handler#,128
Before Change
// TODO: Use JsonObjects for risk limits and move it to store(message) method as well
eb.consumer("ers.RiskLimit", message -> storeRiskLimit(message));
completer.handle(Future.succeededFuture());
}
private void startQueryHandlers(Handler<AsyncResult<Void>> completer)
After Change
eb.consumer("ers.RiskLimit", message -> storeRiskLimit(message));
LOG.info("Event bus store handlers subscribed");
return Future.succeededFuture();
}
private Future<Void> startQueryHandlers(Void unused)